org.apache.flink.graph.drivers.input

Class CSV<K extends Comparable<K>>

java.lang.Object

org.apache.flink.graph.drivers.parameter.ParameterizedBase

org.apache.flink.graph.drivers.input.InputBase<K,NullValue,NullValue>

org.apache.flink.graph.drivers.input.CSV<K>

Type Parameters:

K - key type

All Implemented Interfaces:

Input<K,NullValue,NullValue>, Parameterized

public class CSV<K extends Comparable<K>>
extends InputBase<K,NullValue,NullValue>

Read a Graph from a CSV file using IntValue, LongValue, or StringValue keys.

Field Summary

Fields inherited from class org.apache.flink.graph.drivers.input.InputBase

parallelism

Constructor Summary

Constructors

Constructor and Description
CSV()

Method Summary

Modifier and Type	Method and Description
Graph<K,NullValue,NullValue>	create(ExecutionEnvironment env) Create the input Graph.
String	getIdentity() A human-readable identifier summarizing the input and configuration.

Methods inherited from class org.apache.flink.graph.drivers.input.InputBase

getName

Methods inherited from class org.apache.flink.graph.drivers.parameter.ParameterizedBase

addParameter, configure, getUsage

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.graph.drivers.parameter.Parameterized

configure, getUsage

Constructor Detail

CSV

public CSV()

Method Detail

getIdentity

public String getIdentity()

Description copied from interface: Input

A human-readable identifier summarizing the input and configuration.

Returns:

the input identifier

create

public Graph<K,NullValue,NullValue> create(ExecutionEnvironment env)
                                    throws Exception

Description copied from interface: Input

Create the input Graph.

Parameters:

env - the ExecutionEnvironment

Returns:

the input Graph

Throws:

Exception