prajna.structure.writer

Class SolrUpdater

java.lang.Object

prajna.io.WebFormatWriter<DataRecord>

prajna.structure.writer.StructureWriter

prajna.structure.writer.SolrUpdater

All Implemented Interfaces:

FormatWriter<DataRecord>

public class SolrUpdater
extends StructureWriter

Utility class for writing DataRecords to a Solr instance.

Author:

Edward Swing

Constructor Summary

Constructors

Constructor and Description
SolrUpdater(java.lang.String solrUrl) Create an instance of a SolrUpdater for the specified URL

Method Summary

Methods

Modifier and Type	Method and Description
void	clear() Clear any stored settings and data
void	close() Close this writer.
java.lang.String	getDestination() Get the destination for this SolrUpdater.
static void	main(java.lang.String[] args) Utility main method for this class.
void	setDebug(boolean flag) Set the debug flag
void	setDestination(java.lang.String destination) Set the destination for this writer.
void	setTimeZone(java.util.TimeZone zone) Set the time zone for Date-Time values entered into Solr
void	setWriteLimit(int limit) Set the maximum number of records written to the server.
void	updateData(java.util.Collection<DataRecord> records) Update the solr instance with the set of records.
void	writeCommand(java.lang.String cmd) Write a command to the solr instance.
void	writeData(java.util.Collection<DataRecord> records) Write the collection of records to the Solr instance.
void	writeGraph(Graph<DataRecord,DataRecord> graph) Write graph data.
void	writeGrid(Grid<DataRecord> grid) Write Grid data
void	writeTree(Tree<DataRecord> tree) Write tree data

Methods inherited from class prajna.io.WebFormatWriter

getContentType, getWriter, setWriter

Methods inherited from class java.lang.Object

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

Constructor Detail

SolrUpdater

public SolrUpdater(java.lang.String solrUrl)

Create an instance of a SolrUpdater for the specified URL

Parameters:

solrUrl - The update URL for the solr instance

Method Detail

clear

public void clear()

Clear any stored settings and data

Specified by:

clear in class StructureWriter

close

public void close()

Close this writer. This method sends a commit and an optimize request to the Solr server

getDestination

public java.lang.String getDestination()

Get the destination for this SolrUpdater. This returns the base Solr URL.

Specified by:

getDestination in interface FormatWriter<DataRecord>

Overrides:

getDestination in class WebFormatWriter<DataRecord>

Returns:

the destination URL

setDebug

public void setDebug(boolean flag)

Set the debug flag

Parameters:

flag - the debug flag

setDestination

public void setDestination(java.lang.String destination)

Set the destination for this writer. This method sets the base Solr URL for this writer

Specified by:

setDestination in interface FormatWriter<DataRecord>

Overrides:

setDestination in class WebFormatWriter<DataRecord>

Parameters:

destination - the destination for this writer.

setTimeZone

public void setTimeZone(java.util.TimeZone zone)

Set the time zone for Date-Time values entered into Solr

Parameters:

zone - the time zone

setWriteLimit

public void setWriteLimit(int limit)

Set the maximum number of records written to the server. The default is 1000.

Parameters:

limit - the maximum number of records written with a single call

updateData

public void updateData(java.util.Collection<DataRecord> records)
                throws java.io.IOException

Update the solr instance with the set of records. This executes an Update request on the Solr server

Parameters:

records - the set of records

Throws:

java.io.IOException - if there is a problem executing the request

writeCommand

public void writeCommand(java.lang.String cmd)
                  throws java.io.IOException

Write a command to the solr instance. This writes a simple command, such as commit or optimize.

Parameters:

cmd - the command to write

Throws:

java.io.IOException - if there is a problem executing the request

writeData

public void writeData(java.util.Collection<DataRecord> records)
               throws java.io.IOException

Write the collection of records to the Solr instance. This method writes the records, and pushes them to the Solr server with an ADD request.

Parameters:

records - The collection of records to write

Throws:

java.io.IOException - if there is a problem executing the request

writeGraph

public void writeGraph(Graph<DataRecord,DataRecord> graph)

Write graph data. This method simply calls writeData() with the nodeSet and edgeSet.

Specified by:

writeGraph in class StructureWriter

Parameters:

graph - the graph

writeGrid

public void writeGrid(Grid<DataRecord> grid)

Write Grid data

Specified by:

writeGrid in class StructureWriter

Parameters:

grid - the grid

writeTree

public void writeTree(Tree<DataRecord> tree)

Write tree data

Specified by:

writeTree in class StructureWriter

Parameters:

tree - the tree data

main

public static void main(java.lang.String[] args)
                 throws java.io.IOException

Utility main method for this class. This main method simply closes a SolrUpdater instance, which sends a commit and an optimize command to the server

Parameters:

args - command line arguments. The first argument should be the address of the Solr server

Throws:

java.io.IOException - if there is a problem writing to the server