Java源码示例:org.apache.flink.api.java.io.SplitDataProperties
示例1
/**
* Returns the {@link org.apache.flink.api.java.io.SplitDataProperties} for the
* {@link org.apache.flink.core.io.InputSplit}s of this DataSource
* for configurations.
*
* <p>SplitDataProperties can help to generate more efficient execution plans.
*
*
* <p><b>
* IMPORTANT: Incorrect configuration of SplitDataProperties can cause wrong results!
* </b>
*
* @return The SplitDataProperties for the InputSplits of this DataSource.
*/
@PublicEvolving
public SplitDataProperties<OUT> getSplitDataProperties() {
if (this.splitDataProperties == null) {
this.splitDataProperties = new SplitDataProperties<OUT>(this);
}
return this.splitDataProperties;
}
示例2
/**
* Returns the {@link org.apache.flink.api.java.io.SplitDataProperties} for the
* {@link org.apache.flink.core.io.InputSplit}s of this DataSource
* for configurations.
*
* <p>SplitDataProperties can help to generate more efficient execution plans.
*
*
* <p><b>
* IMPORTANT: Incorrect configuration of SplitDataProperties can cause wrong results!
* </b>
*
* @return The SplitDataProperties for the InputSplits of this DataSource.
*/
@PublicEvolving
public SplitDataProperties<OUT> getSplitDataProperties() {
if (this.splitDataProperties == null) {
this.splitDataProperties = new SplitDataProperties<OUT>(this);
}
return this.splitDataProperties;
}
示例3
/**
* Returns the {@link org.apache.flink.api.java.io.SplitDataProperties} for the
* {@link org.apache.flink.core.io.InputSplit}s of this DataSource
* for configurations.
*
* <p>SplitDataProperties can help to generate more efficient execution plans.
*
*
* <p><b>
* IMPORTANT: Incorrect configuration of SplitDataProperties can cause wrong results!
* </b>
*
* @return The SplitDataProperties for the InputSplits of this DataSource.
*/
@PublicEvolving
public SplitDataProperties<OUT> getSplitDataProperties() {
if (this.splitDataProperties == null) {
this.splitDataProperties = new SplitDataProperties<OUT>(this);
}
return this.splitDataProperties;
}