com.aliyun.odps.storage.internal.io

Class RawArrowRequestBody

java.lang.Object

okhttp3.RequestBody

com.aliyun.odps.storage.internal.io.RawArrowRequestBody

public class RawArrowRequestBody
extends okhttp3.RequestBody

Nested Class Summary

Nested classes/interfaces inherited from class okhttp3.RequestBody

okhttp3.RequestBody.Companion

Field Summary

Fields inherited from class okhttp3.RequestBody

Companion

Constructor Summary

Constructors

Constructor and Description
RawArrowRequestBody(List<byte[]> batches, org.apache.arrow.vector.types.pojo.Schema arrowSchema, org.apache.arrow.vector.ipc.message.IpcOption ipcOption)

Method Summary

Modifier and Type	Method and Description
okhttp3.MediaType	contentType()
long	getTotalBytes()
void	writeTo(okio.BufferedSink sink)

Methods inherited from class okhttp3.RequestBody

contentLength, create, create, create, create, create, create, create, create, create, create, create, create, create, isDuplex, isOneShot

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RawArrowRequestBody

public RawArrowRequestBody(List<byte[]> batches,
                           org.apache.arrow.vector.types.pojo.Schema arrowSchema,
                           org.apache.arrow.vector.ipc.message.IpcOption ipcOption)

Method Detail

contentType

public okhttp3.MediaType contentType()

Specified by:

contentType in class okhttp3.RequestBody

writeTo

public void writeTo(@NotNull
                    okio.BufferedSink sink)
             throws IOException

Specified by:

writeTo in class okhttp3.RequestBody

Throws:

IOException

getTotalBytes

public long getTotalBytes()