Package | Description |
---|---|
org.apache.flink.api.common.io | |
org.apache.flink.api.java.io |
Modifier and Type | Method and Description |
---|---|
GenericInputSplit[] |
GenericInputFormat.createInputSplits(int numSplits) |
Modifier and Type | Method and Description |
---|---|
DefaultInputSplitAssigner |
GenericInputFormat.getInputSplitAssigner(GenericInputSplit[] splits) |
void |
GenericInputFormat.open(GenericInputSplit split) |
Modifier and Type | Method and Description |
---|---|
void |
ParallelIteratorInputFormat.open(GenericInputSplit split) |
void |
CollectionInputFormat.open(GenericInputSplit split) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.