-
- All Implemented Interfaces:
-
java.lang.AutoCloseable
public final class Driver implements AutoCloseable
The pulsar driver
-
-
Method Summary
Modifier and Type Method Description final DurationgetTimeout()final UnitsetTimeout(Duration timeout)final Stringsubmit(String sql, Integer priority, Boolean asap)Submit an SQL to scrape final List<String>submitAll(Iterable<String> sqls, Integer priority, Boolean asap)Submit SQLs to scrape final Dashboarddashboard()Show my dashboard final ScrapeResponsefindById(String id)Find a scrape response by scrape task id which returned by submit final List<ScrapeResponse>findAllByIds(Iterable<String> ids)Find scrape responses by scrape task ids which returned by submit final Longcount()Count all submitted tasks final List<CompactedScrapeResponse>fetch(Long offset, Integer limit)Fetch limit scrape responses start from offset final Page<CompactedScrapeResponse>download(Integer pageNumber, Integer pageSize)Download scrape responses page by page final GsoncreateGson()Unitclose()-
-
Method Detail
-
getTimeout
final Duration getTimeout()
-
setTimeout
final Unit setTimeout(Duration timeout)
-
submitAll
final List<String> submitAll(Iterable<String> sqls, Integer priority, Boolean asap)
Submit SQLs to scrape
-
findById
final ScrapeResponse findById(String id)
Find a scrape response by scrape task id which returned by submit
-
findAllByIds
final List<ScrapeResponse> findAllByIds(Iterable<String> ids)
Find scrape responses by scrape task ids which returned by submit
-
fetch
final List<CompactedScrapeResponse> fetch(Long offset, Integer limit)
-
download
final Page<CompactedScrapeResponse> download(Integer pageNumber, Integer pageSize)
Download scrape responses page by page
-
createGson
final Gson createGson()
-
-
-
-