public class ColumnEncoderDummycode extends ColumnEncoder
ColumnEncoder.EncoderType
Modifier and Type | Field and Description |
---|---|
int |
_domainSize |
BUILD_ROW_BLOCKS_PER_COLUMN
Constructor and Description |
---|
ColumnEncoderDummycode() |
ColumnEncoderDummycode(int colID) |
ColumnEncoderDummycode(int colID,
int domainSize) |
Modifier and Type | Method and Description |
---|---|
void |
build(CacheBlock in)
Build the transform meta data for the given block input.
|
boolean |
equals(Object o) |
List<DependencyTask<?>> |
getBuildTasks(CacheBlock in) |
int |
getDomainSize() |
FrameBlock |
getMetaData(FrameBlock meta)
Construct a frame block out of the transform meta data.
|
int |
hashCode() |
void |
initMetaData(FrameBlock meta)
Sets up the required meta data for a subsequent call to apply.
|
void |
mergeAt(ColumnEncoder other)
Merges another encoder, of a compatible type, in after a certain position.
|
void |
readExternal(ObjectInput in)
Redirects the default java serialization via externalizable to our default hadoop writable serialization for
efficient broadcast/rdd deserialization.
|
void |
updateDomainSizes(List<ColumnEncoder> columnEncoders) |
void |
updateIndexRanges(long[] beginDims,
long[] endDims,
int colOffset)
Update index-ranges to after encoding.
|
void |
writeExternal(ObjectOutput out)
Redirects the default java serialization via externalizable to our default hadoop writable serialization for
efficient broadcast/rdd serialization.
|
apply, apply, buildPartial, compareTo, getApplyTasks, getBuildTask, getColID, getColMapping, getPartialBuildTask, getPartialMergeBuildTask, getSparseRowsWZeros, isApplicable, isApplicable, prepareBuildPartial, setColID, shiftCol
public ColumnEncoderDummycode()
public ColumnEncoderDummycode(int colID)
public ColumnEncoderDummycode(int colID, int domainSize)
public void build(CacheBlock in)
Encoder
in
- input frame blockpublic List<DependencyTask<?>> getBuildTasks(CacheBlock in)
getBuildTasks
in class ColumnEncoder
public void mergeAt(ColumnEncoder other)
ColumnEncoder
ColumnEncoders
are compatible with themselves and EncoderComposite
is compatible with
every other ColumnEncoders
. MultiColumnEncoders
are compatible with every encodermergeAt
in class ColumnEncoder
other
- the encoder that should be merged inpublic void updateIndexRanges(long[] beginDims, long[] endDims, int colOffset)
ColumnEncoder
updateIndexRanges
in interface Encoder
updateIndexRanges
in class ColumnEncoder
beginDims
- begin dimensions of rangeendDims
- end dimensions of rangecolOffset
- is applied to begin and endDimspublic void updateDomainSizes(List<ColumnEncoder> columnEncoders)
public FrameBlock getMetaData(FrameBlock meta)
Encoder
meta
- output frame blockpublic void initMetaData(FrameBlock meta)
Encoder
meta
- frame blockpublic void writeExternal(ObjectOutput out) throws IOException
ColumnEncoder
writeExternal
in interface Externalizable
writeExternal
in class ColumnEncoder
out
- object outputIOException
- if IOException occurspublic void readExternal(ObjectInput in) throws IOException
ColumnEncoder
readExternal
in interface Externalizable
readExternal
in class ColumnEncoder
in
- object inputIOException
- if IOException occurpublic int getDomainSize()
Copyright © 2021 The Apache Software Foundation. All rights reserved.