Package | Description |
---|---|
org.cylondata.cylon |
Modifier and Type | Method and Description |
---|---|
Table |
Table.distributedJoin(Table rightTable,
JoinConfig joinConfig)
Apply the join algorithm across a distributed set of nodes/dataset
|
<I> Table |
Table.filter(int columnIndex,
Filter<I> filterLogic)
Filter out rows of a table based on a single column
|
static Table |
Table.fromColumns(List<Column> columns)
Create a
Table by combining a list of columns |
static Table |
Table.fromCSV(CylonContext ctx,
String path)
This method will load a table by reading the data from a CSV file.
|
static Table |
Table.fromCSV(String path,
List<org.apache.arrow.vector.types.Types.MinorType> dataTypes)
This method will load a table by reading the data from a CSV file.
|
Table |
Table.join(Table rightTable,
JoinConfig joinConfig)
Join two tables based on the value of the columns
|
static Table |
Table.merge(CylonContext ctx,
Table... tables)
Merge a set of similar tables into a single table.
|
Table |
Table.select(Selector selector)
This method can be used to filter out some rows from a table based on a
user defined logic
|
Table |
Table.sort(int columnIndex)
Sort the rows of a table based on the value of a column
|
Modifier and Type | Method and Description |
---|---|
List<Table> |
Table.hashPartition(List<Integer> hashColumns,
int noOfPartitions)
Partition a table based on the hash value of the specified columns
|
List<Table> |
Table.roundRobinPartition(int noOfPartitions)
Partition a table into n partitions of similar size
|
Modifier and Type | Method and Description |
---|---|
Table |
Table.distributedJoin(Table rightTable,
JoinConfig joinConfig)
Apply the join algorithm across a distributed set of nodes/dataset
|
Table |
Table.join(Table rightTable,
JoinConfig joinConfig)
Join two tables based on the value of the columns
|
static Table |
Table.merge(CylonContext ctx,
Table... tables)
Merge a set of similar tables into a single table.
|
Copyright © 2020. All rights reserved.