org.locationtech.geowave.service

Interface IngestService

public interface IngestService

Method Summary

Modifier and Type	Method and Description
javax.ws.rs.core.Response	kafkaToGW(String storeName, String indexList, String kafkaPropertyFile, String visibility, String groupId, String bootstrapServers, String autoOffsetReset, String maxPartitionFetchBytes, String consumerTimeoutMs, Boolean reconnectOnTimeout, Integer batchSize, String extensions, String formats)
javax.ws.rs.core.Response	listPlugins()
javax.ws.rs.core.Response	localToGW(String fileOrDirectory, String storeName, String indexList, Integer threads, String visibility, String extensions, String formats)
javax.ws.rs.core.Response	localToHdfs(String fileOrDirectory, String pathToBaseDirectoryToWriteTo, String extensions, String formats)
javax.ws.rs.core.Response	localToKafka(String fileOrDirectory, String kafkaPropertyFile, String bootstrapServers, String retryBackoffMs, String extensions, String formats)
javax.ws.rs.core.Response	localToMrGW(String fileOrDirectory, String pathToBaseDirectoryToWriteTo, String storeName, String indexList, String visibility, String jobTrackerHostPort, String resourceManger, String extensions, String formats)
javax.ws.rs.core.Response	mrToGW(String pathToBaseDirectoryToWriteTo, String storeName, String indexList, String visibility, String jobTrackerHostPort, String resourceManger, String extensions, String formats)
javax.ws.rs.core.Response	sparkToGW(String inputDirectory, String storeName, String indexList, String visibility, String appName, String host, String master, Integer numExecutors, Integer numCores, String extensions, String formats)

Method Detail

listPlugins

javax.ws.rs.core.Response listPlugins()

kafkaToGW

javax.ws.rs.core.Response kafkaToGW(String storeName,
                                    String indexList,
                                    String kafkaPropertyFile,
                                    String visibility,
                                    String groupId,
                                    String bootstrapServers,
                                    String autoOffsetReset,
                                    String maxPartitionFetchBytes,
                                    String consumerTimeoutMs,
                                    Boolean reconnectOnTimeout,
                                    Integer batchSize,
                                    String extensions,
                                    String formats)

localToGW

javax.ws.rs.core.Response localToGW(String fileOrDirectory,
                                    String storeName,
                                    String indexList,
                                    Integer threads,
                                    String visibility,
                                    String extensions,
                                    String formats)

localToHdfs

javax.ws.rs.core.Response localToHdfs(String fileOrDirectory,
                                      String pathToBaseDirectoryToWriteTo,
                                      String extensions,
                                      String formats)

localToKafka

javax.ws.rs.core.Response localToKafka(String fileOrDirectory,
                                       String kafkaPropertyFile,
                                       String bootstrapServers,
                                       String retryBackoffMs,
                                       String extensions,
                                       String formats)

localToMrGW

javax.ws.rs.core.Response localToMrGW(String fileOrDirectory,
                                      String pathToBaseDirectoryToWriteTo,
                                      String storeName,
                                      String indexList,
                                      String visibility,
                                      String jobTrackerHostPort,
                                      String resourceManger,
                                      String extensions,
                                      String formats)

mrToGW

javax.ws.rs.core.Response mrToGW(String pathToBaseDirectoryToWriteTo,
                                 String storeName,
                                 String indexList,
                                 String visibility,
                                 String jobTrackerHostPort,
                                 String resourceManger,
                                 String extensions,
                                 String formats)

sparkToGW

javax.ws.rs.core.Response sparkToGW(String inputDirectory,
                                    String storeName,
                                    String indexList,
                                    String visibility,
                                    String appName,
                                    String host,
                                    String master,
                                    Integer numExecutors,
                                    Integer numCores,
                                    String extensions,
                                    String formats)