GeoEntityManager

public abstract class GeoEntityManager<E extends GeoEntity, T extends RawData> extends EntityManager

Fields

geoConfigurationManager

GeoConfigurationManager geoConfigurationManager

log

protected Logger log

timer

Stopwatch timer

Constructors

GeoEntityManager

public GeoEntityManager()

Methods

createBasicEntity

protected abstract E createBasicEntity(T record, Session session)

filter

protected boolean filter(JsonNode record, ObjectNode importConfiguration)

generateUUID

protected abstract UUID generateUUID(T rawData)

getBaseEndpoint

public URI getBaseEndpoint()

getBaseName

protected abstract String getBaseName()

getConfiguration

protected GeoConfiguration getConfiguration()

getCustomerId

public int getCustomerId()

getDomain

public abstract String getDomain()

getEntityClass

protected abstract Class<E> getEntityClass()

getHandledURISubstrings

public Collection<String> getHandledURISubstrings()

getJobId

public int getJobId()

getLocalSubscriptionFolder

public String getLocalSubscriptionFolder()

getLog

protected Logger getLog()

getObjectMapper

protected ObjectMapper getObjectMapper()

getRawClass

protected abstract Class<T> getRawClass()

getRegisterManager

public GeoRegisterManager getRegisterManager()

getRegistrationFetcher

protected Communicator getRegistrationFetcher()

handlesOwnSaves

public boolean handlesOwnSaves()

isSetupSubscriptionEnabled

public boolean isSetupSubscriptionEnabled()

parseData

public List<? extends Registration> parseData(InputStream jsonData, ImportMetadata importMetadata)

parseDeletionData

public void parseDeletionData(InputStream jsonData)

parseJsonStream

public static long parseJsonStream(String jsonData, String searchKey, ObjectMapper objectMapper, Consumer<JsonNode> callback)

parseJsonStream

public static long parseJsonStream(InputStream jsonData, Charset charset, String searchKey, ObjectMapper objectMapper, Consumer<JsonNode> callback)

pullEnabled

public boolean pullEnabled()

Should return whether the configuration is set so that pulls are enabled for this entitymanager

setRegisterManager

public void setRegisterManager(RegisterManager registerManager)

updateEntity

protected void updateEntity(E entity, T rawData, ImportMetadata importMetadata)