com.splicemachine.derby.stream.backup

Class GetAllPartitionFunction

java.lang.Object

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

com.splicemachine.derby.stream.function.SpliceFlatMapFunction<SpliceOperation,java.util.Iterator<BackupItem>,BackupPartition>

com.splicemachine.derby.stream.backup.GetAllPartitionFunction

All Implemented Interfaces:

ExternalizableFlatMapFunction<java.util.Iterator<BackupItem>,BackupPartition>, java.io.Externalizable, java.io.Serializable, org.spark_project.guava.base.Function<java.util.Iterator<BackupItem>,java.util.Iterator<BackupPartition>>

public class GetAllPartitionFunction
extends SpliceFlatMapFunction<SpliceOperation,java.util.Iterator<BackupItem>,BackupPartition>
implements java.io.Externalizable

Created by jyuan on 11/25/17.

See Also:

Serialized Form

Field Summary

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

operationContext

Constructor Summary

Constructors

Constructor and Description
GetAllPartitionFunction()

Method Summary

Modifier and Type	Method and Description
java.util.Iterator<BackupPartition>	call(java.util.Iterator<BackupItem> backupItems)

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, readExternal, reset, writeExternal

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Externalizable

readExternal, writeExternal

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

equals

Constructor Detail

GetAllPartitionFunction

public GetAllPartitionFunction()

Method Detail

call

public java.util.Iterator<BackupPartition> call(java.util.Iterator<BackupItem> backupItems)
                                         throws java.lang.Exception

Specified by:

call in interface ExternalizableFlatMapFunction<java.util.Iterator<BackupItem>,BackupPartition>

Throws:

java.lang.Exception