com.splicemachine.derby.stream.function

Class RowAndIndexGenerator

java.lang.Object

com.splicemachine.derby.stream.function.AbstractSpliceFunction<Op>

com.splicemachine.derby.stream.function.SpliceFlatMapFunction<SpliceBaseOperation,ExecRow,scala.Tuple2<java.lang.Long,scala.Tuple2<byte[],byte[]>>>

com.splicemachine.derby.stream.function.RowAndIndexGenerator

All Implemented Interfaces:

ExternalizableFlatMapFunction<ExecRow,scala.Tuple2<java.lang.Long,scala.Tuple2<byte[],byte[]>>>, java.io.Externalizable, java.io.Serializable, org.spark_project.guava.base.Function<ExecRow,java.util.Iterator<scala.Tuple2<java.lang.Long,scala.Tuple2<byte[],byte[]>>>>

Direct Known Subclasses:

BulkDeleteRowIndexGenerationFunction, BulkInsertRowIndexGenerationFunction

public abstract class RowAndIndexGenerator
extends SpliceFlatMapFunction<SpliceBaseOperation,ExecRow,scala.Tuple2<java.lang.Long,scala.Tuple2<byte[],byte[]>>>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected long	heapConglom
protected IndexTransformFunction[]	indexTransformFunctions
protected boolean	initialized
protected java.util.ArrayList<com.splicemachine.ddl.DDLMessage.TentativeIndex>	tentativeIndices
protected TxnView	txn

Fields inherited from class com.splicemachine.derby.stream.function.AbstractSpliceFunction

operationContext

Constructor Summary

Constructors

Constructor and Description
RowAndIndexGenerator()
RowAndIndexGenerator(OperationContext operationContext, TxnView txn, long heapConglom, java.util.ArrayList<com.splicemachine.ddl.DDLMessage.TentativeIndex> tentativeIndices)

Method Summary

Modifier and Type	Method and Description
abstract java.util.Iterator<scala.Tuple2<java.lang.Long,scala.Tuple2<byte[],byte[]>>>	call(ExecRow locatedRow)
void	readExternal(java.io.ObjectInput in)
void	writeExternal(java.io.ObjectOutput out)

Methods inherited from class com.splicemachine.derby.stream.function.SpliceFlatMapFunction

apply

Methods inherited from class com.splicemachine.derby.stream.function.AbstractSpliceFunction

getActivation, getOperation, getPrettyFunctionName, getSparkName, prepare, reset

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.spark_project.guava.base.Function

equals

Field Detail

txn

protected TxnView txn

heapConglom

protected long heapConglom

tentativeIndices

protected java.util.ArrayList<com.splicemachine.ddl.DDLMessage.TentativeIndex> tentativeIndices

indexTransformFunctions

protected IndexTransformFunction[] indexTransformFunctions

initialized

protected boolean initialized

Constructor Detail

RowAndIndexGenerator

public RowAndIndexGenerator()

RowAndIndexGenerator

public RowAndIndexGenerator(OperationContext operationContext,
                            TxnView txn,
                            long heapConglom,
                            java.util.ArrayList<com.splicemachine.ddl.DDLMessage.TentativeIndex> tentativeIndices)

Method Detail

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Specified by:

writeExternal in interface java.io.Externalizable

Overrides:

writeExternal in class AbstractSpliceFunction<SpliceBaseOperation>

Throws:

java.io.IOException

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException,
                         java.lang.ClassNotFoundException

Specified by:

readExternal in interface java.io.Externalizable

Overrides:

readExternal in class AbstractSpliceFunction<SpliceBaseOperation>

Throws:

java.io.IOException

java.lang.ClassNotFoundException

call

public abstract java.util.Iterator<scala.Tuple2<java.lang.Long,scala.Tuple2<byte[],byte[]>>> call(ExecRow locatedRow)
                                                                                           throws java.lang.Exception

Throws:

java.lang.Exception