diff --git a/pkg/exchange/batch/option.go b/pkg/exchange/batch/option.go
new file mode 100644
index 000000000..67f18e608
--- /dev/null
+++ b/pkg/exchange/batch/option.go
@@ -0,0 +1,12 @@
+package batch
+
+import "time"
+
+type Option func(query *AsyncTimeRangedBatchQuery)
+
+// JumpIfEmpty jump the startTime + duration when the result is empty
+func JumpIfEmpty(duration time.Duration) Option {
+	return func(query *AsyncTimeRangedBatchQuery) {
+		query.JumpIfEmpty = duration
+	}
+}
diff --git a/pkg/exchange/batch/trade.go b/pkg/exchange/batch/trade.go
index 1c91da777..4fce26b65 100644
--- a/pkg/exchange/batch/trade.go
+++ b/pkg/exchange/batch/trade.go
@@ -17,7 +17,7 @@ type TradeBatchQuery struct {
 	types.ExchangeTradeHistoryService
 }
 
-func (e TradeBatchQuery) Query(ctx context.Context, symbol string, options *types.TradeQueryOptions) (c chan types.Trade, errC chan error) {
+func (e TradeBatchQuery) Query(ctx context.Context, symbol string, options *types.TradeQueryOptions, opts ...Option) (c chan types.Trade, errC chan error) {
 	if options.EndTime == nil {
 		now := time.Now()
 		options.EndTime = &now
@@ -45,6 +45,10 @@ func (e TradeBatchQuery) Query(ctx context.Context, symbol string, options *type
 		JumpIfEmpty: 24 * time.Hour,
 	}
 
+	for _, opt := range opts {
+		opt(query)
+	}
+
 	c = make(chan types.Trade, 100)
 	errC = query.Query(ctx, c, startTime, endTime)
 	return c, errC