public class PivotTransform extends BaseTransform
inputSchema
Constructor and Description |
---|
PivotTransform(String keyColumnName,
String valueColumnName) |
PivotTransform(String keyColumnName,
String valueColumnName,
Writable defaultValue) |
Modifier and Type | Method and Description |
---|---|
String |
columnName()
Returns a singular column name
this op is meant to run on
|
String[] |
columnNames()
Returns column names
this op is meant to run on
|
List<Writable> |
map(List<Writable> writables)
Transform a writable
in to another writable
|
Object |
map(Object input)
Transform an object
in to another object
|
Object |
mapSequence(Object sequence)
Transform a sequence
|
String |
outputColumnName()
The output column name
after the operation has been applied
|
String[] |
outputColumnNames()
The output column names
This will often be the same as the input
|
Schema |
transform(Schema inputSchema) |
getInputSchema, mapSequence, setInputSchema, toString
public PivotTransform(String keyColumnName, String valueColumnName)
keyColumnName
- Key column to expandvalueColumnName
- Name of the column that contains the valuepublic String outputColumnName()
ColumnOp
public String[] outputColumnNames()
ColumnOp
public String[] columnNames()
ColumnOp
public String columnName()
ColumnOp
public List<Writable> map(List<Writable> writables)
Transform
writables
- the record to transformpublic Object map(Object input)
Transform
input
- the record to transformCopyright © 2020. All rights reserved.