public abstract class ShopifyApiReader extends IntegrationReader
DataEndpoint.State
Modifier and Type | Field and Description |
---|---|
protected ShopifyService |
service |
fieldLineage, recordLineage
lastRecord, PRODUCT, PRODUCT_VERSION, VENDOR, XML_INPUT_FACTORY_KEY
BUFFER_SIZE, captureElapsedTime, DEFAULT_READ_BUFFER_SIZE
id, log, name, TIMESTAMP_FORMAT
Constructor and Description |
---|
ShopifyApiReader(String domain,
String token) |
Modifier and Type | Method and Description |
---|---|
DataException |
addExceptionProperties(DataException exception)
Adds this endpoint's current state to a
DataException . |
void |
close()
Indicates that this endpoint has finished reading or writing.
|
int |
getBatchSize() |
long |
getInitialRetryDelay() |
int |
getMaxRetryCount() |
protected String |
getNextPageInfo() |
protected abstract ArrayValue |
getRecordsFromResponse(Record record) |
IRetryStrategy |
getRetryStrategy() |
protected abstract Record |
invokeRequest() |
void |
open()
Makes this endpoint ready for reading or writing.
|
protected Record |
readImpl()
Overridden by subclasses to read the next record from this
DataReader . |
ShopifyApiReader |
setBatchSize(int batchSize) |
ShopifyApiReader |
setInitialRetryDelay(long initialRetryDelay) |
ShopifyApiReader |
setMaxRetryCount(int maxRetryCount) |
ShopifyApiReader |
setRetryStrategy(IRetryStrategy retryStrategy) |
addLineage, available, getBufferSize, getNestedEndpoint, getNestedReader, getRootEndpoint, getRootReader, isExhausted, isLineageSupported, isSaveLineage, peek, pop, push, read, setSaveLineage, skip
decrementRecordCount, enableJmx, getLastRecord, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, incrementRecordCount, isRecordCountBigInteger, resetRecordCount, toString
addElapsedtime, assertClosed, assertNotOpened, assertOpened, finalize, getClosedOn, getDescription, getElapsedTime, getElapsedTimeAsString, getOpenedOn, getOpenElapsedTime, getOpenElapsedTimeAsString, getSelfTime, getSelfTimeAsString, getState, isCaptureElapsedTime, isClosed, isOpen, setCaptureElapsedTime, setDescription
protected ShopifyService service
public int getBatchSize()
public ShopifyApiReader setBatchSize(int batchSize)
public IRetryStrategy getRetryStrategy()
public ShopifyApiReader setRetryStrategy(IRetryStrategy retryStrategy)
public int getMaxRetryCount()
public ShopifyApiReader setMaxRetryCount(int maxRetryCount)
public long getInitialRetryDelay()
public ShopifyApiReader setInitialRetryDelay(long initialRetryDelay)
protected String getNextPageInfo()
public void open() throws DataException
DataEndpoint
open
in class IntegrationReader
DataException
public void close() throws DataException
DataEndpoint
close
in class DataEndpoint
DataException
protected Record readImpl() throws Throwable
DataReader
DataReader
. The default
implementation of DataReader.read()
now insures that this method will not be called again after it returns
a null
.
If no record is available, null
will be returned.
readImpl
in class DataReader
Throwable
protected abstract Record invokeRequest()
protected abstract ArrayValue getRecordsFromResponse(Record record)
public DataException addExceptionProperties(DataException exception)
Endpoint
DataException
. Since this method is called whenever an
exception is thrown, subclasses should override it to add their specific information.addExceptionProperties
in class DataReader
Copyright (c) 2006-2023 North Concepts Inc. All Rights Reserved.