org.apache.flink.cdc.common.types.utils.runtime

类 DataInputViewStream

java.lang.Object

java.io.InputStream

org.apache.flink.cdc.common.types.utils.runtime.DataInputViewStream

所有已实现的接口:

Closeable, AutoCloseable

public class DataInputViewStream
extends InputStream

An input stream that draws its data from a DataInputView.

字段概要

字段

限定符和类型	字段和说明
protected org.apache.flink.core.memory.DataInputView	inputView

构造器概要

构造器

构造器和说明
DataInputViewStream(org.apache.flink.core.memory.DataInputView inputView)

方法概要

限定符和类型	方法和说明
org.apache.flink.core.memory.DataInputView	getInputView()
int	read()
int	read(byte[] b, int off, int len)
long	skip(long n)

从类继承的方法 java.io.InputStream

available, close, mark, markSupported, read, reset

从类继承的方法 java.lang.Object

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

字段详细资料

inputView

protected org.apache.flink.core.memory.DataInputView inputView

构造器详细资料

DataInputViewStream

public DataInputViewStream(org.apache.flink.core.memory.DataInputView inputView)

方法详细资料

getInputView

public org.apache.flink.core.memory.DataInputView getInputView()

read

public int read()
         throws IOException

指定者:

read 在类中 InputStream

抛出:

IOException

skip

public long skip(long n)
          throws IOException

覆盖:

skip 在类中 InputStream

抛出:

IOException

read

public int read(byte[] b,
                int off,
                int len)
         throws IOException

覆盖:

read 在类中 InputStream

抛出:

IOException