| Package | Description |
|---|---|
| com.hazelcast.jet.container |
Provides API to work with JET-container level
|
| com.hazelcast.jet.dag.tap |
Provides API to work with taps
|
| Modifier and Type | Method and Description |
|---|---|
JetTupleFactory |
ContainerDescriptor.getTupleFactory() |
| Modifier and Type | Method and Description |
|---|---|
protected DataReader |
MultiMapSource.getReader(ContainerDescriptor containerDescriptor,
JetTupleFactory tupleFactory,
int partitionId) |
protected DataReader |
MapSource.getReader(ContainerDescriptor containerDescriptor,
JetTupleFactory tupleFactory,
int partitionId) |
DataReader[] |
SourceTap.getReaders(ContainerDescriptor containerDescriptor,
Vertex vertex,
JetTupleFactory tupleFactory)
Array of the input readers
|
DataReader[] |
MapSource.getReaders(ContainerDescriptor containerDescriptor,
Vertex vertex,
JetTupleFactory tupleFactory) |
DataReader[] |
ListSource.getReaders(ContainerDescriptor containerDescriptor,
Vertex vertex,
JetTupleFactory tupleFactory) |
DataReader[] |
FileSource.getReaders(ContainerDescriptor containerDescriptor,
Vertex vertex,
JetTupleFactory tupleFactory) |
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.