Package | Description |
---|---|
org.apache.flink.graph |
Modifier and Type | Method and Description |
---|---|
GraphCsvReader |
GraphCsvReader.fieldDelimiterEdges(String delimiter)
Configures the Delimiter that separates fields in a row for the CSV reader used to read the
edges (
',' ) is used by default. |
GraphCsvReader |
GraphCsvReader.fieldDelimiterVertices(String delimiter)
Configures the Delimiter that separates fields in a row for the CSV reader used to read the
vertices (
',' ) is used by default. |
static GraphCsvReader |
Graph.fromCsvReader(String edgesPath,
ExecutionEnvironment context)
Creates a graph from a CSV file of edges.
|
static <K,VV> GraphCsvReader |
Graph.fromCsvReader(String edgesPath,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment context)
Creates a graph from a CSV file of edges.
|
static GraphCsvReader |
Graph.fromCsvReader(String verticesPath,
String edgesPath,
ExecutionEnvironment context)
Creates a Graph from a CSV file of vertices and a CSV file of edges.
|
GraphCsvReader |
GraphCsvReader.ignoreCommentsEdges(String commentPrefix)
Configures the string that starts comments for the Edge Csv Reader.
|
GraphCsvReader |
GraphCsvReader.ignoreCommentsVertices(String commentPrefix)
Configures the string that starts comments for the Vertex Csv Reader.
|
GraphCsvReader |
GraphCsvReader.ignoreFirstLineEdges()
Sets the CSV reader for the Edges file to ignore the first line.
|
GraphCsvReader |
GraphCsvReader.ignoreFirstLineVertices()
Sets the CSV reader for the Vertices file to ignore the first line.
|
GraphCsvReader |
GraphCsvReader.ignoreInvalidLinesEdges()
Sets the CSV reader for the Edges file to ignore any invalid lines.
|
GraphCsvReader |
GraphCsvReader.ignoreInvalidLinesVertices()
Sets the CSV reader Vertices file to ignore any invalid lines.
|
GraphCsvReader |
GraphCsvReader.includeFieldsEdges(boolean... edgeFields)
Configures which fields of the CSV file containing edges data should be included and which
should be skipped.
|
GraphCsvReader |
GraphCsvReader.includeFieldsEdges(long mask)
Configures which fields of the CSV file containing edges data should be included and which
should be skipped.
|
GraphCsvReader |
GraphCsvReader.includeFieldsEdges(String mask)
Configures which fields of the CSV file containing edges data should be included and which
should be skipped.
|
GraphCsvReader |
GraphCsvReader.includeFieldsVertices(boolean... vertexFields)
Configures which fields of the CSV file containing vertices data should be included and which
should be skipped.
|
GraphCsvReader |
GraphCsvReader.includeFieldsVertices(long mask)
Configures which fields of the CSV file containing vertices data should be included and which
should be skipped.
|
GraphCsvReader |
GraphCsvReader.includeFieldsVertices(String mask)
Configures which fields of the CSV file containing vertices data should be included and which
should be skipped.
|
GraphCsvReader |
GraphCsvReader.lineDelimiterEdges(String delimiter)
Configures the Delimiter that separates rows for the CSV reader used to read the edges
(
'\n' ) is used by default. |
GraphCsvReader |
GraphCsvReader.lineDelimiterVertices(String delimiter)
Configures the Delimiter that separates rows for the CSV reader used to read the vertices
(
'\n' ) is used by default. |
GraphCsvReader |
GraphCsvReader.parseQuotedStringsEdges(char quoteCharacter)
Enables quoted String parsing for Edge Csv Reader.
|
GraphCsvReader |
GraphCsvReader.parseQuotedStringsVertices(char quoteCharacter)
Enables quoted String parsing for Vertex Csv Reader.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.