com.qiniu.android.bigdata.pipeline

Class Pipeline

java.lang.Object

com.qiniu.android.bigdata.pipeline.Pipeline

public final class Pipeline
extends java.lang.Object

Created by long on 2017/7/25.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Pipeline.PumpCompleteHandler

Constructor Summary

Constructors

Constructor and Description
Pipeline(Configuration config)

Method Summary

Modifier and Type	Method and Description
<V> void	pump(java.lang.String repo, java.util.Map<java.lang.String,V> data, java.lang.String token, Pipeline.PumpCompleteHandler handler)
void	pump(java.lang.String repo, java.lang.Object data, java.lang.String token, Pipeline.PumpCompleteHandler handler)
<V> void	pumpMulti(java.lang.String repo, java.util.List<java.util.Map<java.lang.String,V>> data, java.lang.String token, Pipeline.PumpCompleteHandler handler)
<V> void	pumpMulti(java.lang.String repo, java.util.Map<java.lang.String,V>[] data, java.lang.String token, Pipeline.PumpCompleteHandler handler)
<V> void	pumpMultiObjects(java.lang.String repo, java.util.List<V> data, java.lang.String token, Pipeline.PumpCompleteHandler handler)
void	pumpMultiObjects(java.lang.String repo, java.lang.Object[] data, java.lang.String token, Pipeline.PumpCompleteHandler handler)

Methods inherited from class java.lang.Object

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

Constructor Detail

Pipeline

public Pipeline(Configuration config)

Method Detail

pump

public <V> void pump(java.lang.String repo,
                     java.util.Map<java.lang.String,V> data,
                     java.lang.String token,
                     Pipeline.PumpCompleteHandler handler)

pump

public void pump(java.lang.String repo,
                 java.lang.Object data,
                 java.lang.String token,
                 Pipeline.PumpCompleteHandler handler)

pumpMulti

public <V> void pumpMulti(java.lang.String repo,
                          java.util.Map<java.lang.String,V>[] data,
                          java.lang.String token,
                          Pipeline.PumpCompleteHandler handler)

pumpMultiObjects

public void pumpMultiObjects(java.lang.String repo,
                             java.lang.Object[] data,
                             java.lang.String token,
                             Pipeline.PumpCompleteHandler handler)

pumpMultiObjects

public <V> void pumpMultiObjects(java.lang.String repo,
                                 java.util.List<V> data,
                                 java.lang.String token,
                                 Pipeline.PumpCompleteHandler handler)

pumpMulti

public <V> void pumpMulti(java.lang.String repo,
                          java.util.List<java.util.Map<java.lang.String,V>> data,
                          java.lang.String token,
                          Pipeline.PumpCompleteHandler handler)