Package gov.nasa.jpl.aerie.merlin.worker.postgres

Class PostgresProfileStreamer

java.lang.Object

gov.nasa.jpl.aerie.merlin.worker.postgres.PostgresProfileStreamer

All Implemented Interfaces:

gov.nasa.jpl.aerie.merlin.driver.resources.AsyncConsumer<gov.nasa.jpl.aerie.merlin.driver.resources.ResourceProfiles>, AutoCloseable

public class PostgresProfileStreamer
extends Object
implements gov.nasa.jpl.aerie.merlin.driver.resources.AsyncConsumer<gov.nasa.jpl.aerie.merlin.driver.resources.ResourceProfiles>, AutoCloseable

Field Summary

Fields

Modifier and Type	Field	Description
static final org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor	Description
PostgresProfileStreamer(DataSource dataSource, long datasetId)

Method Summary

Modifier and Type	Method	Description
void	accept(gov.nasa.jpl.aerie.merlin.driver.resources.ResourceProfiles resourceProfiles)
void	close()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

log

public static final org.slf4j.Logger log

Constructor Details

PostgresProfileStreamer

public PostgresProfileStreamer(DataSource dataSource,
 long datasetId)
                        throws SQLException

Throws:

SQLException

Method Details

accept

public void accept(gov.nasa.jpl.aerie.merlin.driver.resources.ResourceProfiles resourceProfiles)

Specified by:

accept in interface gov.nasa.jpl.aerie.merlin.driver.resources.AsyncConsumer<gov.nasa.jpl.aerie.merlin.driver.resources.ResourceProfiles>

close

public void close()

Specified by:

close in interface gov.nasa.jpl.aerie.merlin.driver.resources.AsyncConsumer<gov.nasa.jpl.aerie.merlin.driver.resources.ResourceProfiles>

Specified by:

close in interface AutoCloseable