本文整理汇总了Java中org.apache.metamodel.data.DataSet类的典型用法代码示例。如果您正苦于以下问题:Java DataSet类的具体用法?Java DataSet怎么用?Java DataSet使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
DataSet类属于org.apache.metamodel.data包,在下文中一共展示了DataSet类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: insertRowIntoBlockingQueue
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
private void insertRowIntoBlockingQueue(DataSet dataset) throws InterruptedException {
hashedColumn = table.getColumnByName(columnName);
requests = metrics.meter("read thread");
while (dataset.next()) {
Row row = dataset.getRow();
if (horizontal && isKey(row)) {
queue.put(row);
requests.mark();
} else {
if(!horizontal){
queue.put(row);
requests.mark();
}
}
}
}
开发者ID:Iranox,项目名称:mapbench-datadistributor,代码行数:21,代码来源:DataReader.java
示例2: readComplexData
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
public void readComplexData() throws Exception {
Column primaryColumn = dataContext.getTableByQualifiedLabel(joinTable).getColumnByName(secondFkey);
System.out.println(dataContext.query().from(joinTable).select(primaryColumn).groupBy(primaryColumn).toQuery().toString());
DataSet dataSet = dataContext.query().from(joinTable).select(primaryColumn).groupBy(primaryColumn).execute();
while (dataSet.next()) {
arrayData = new ArrayList<Row>();
Object dataValue = dataSet.getRow().getValue(primaryColumn);
DataSet dataSetArray = dataContext.query().from(joinTable).select(forgeinKey).where(primaryColumn)
.eq(dataValue).execute();
System.out.println( dataContext.query().from(joinTable).select(forgeinKey).where(primaryColumn)
.eq(dataValue).toQuery().toSql());
readDataSet(dataSetArray);
ComplexData complexDataObject = new ComplexData(dataSet.getRow(), arrayData);
queueComplexData.put(complexDataObject);
dataSetArray.close();
// dataContext.executeUpdate();
}
insertPosion();
dataSet.close();
}
开发者ID:Iranox,项目名称:mapbench-datadistributor,代码行数:24,代码来源:ComplexDataReader.java
示例3: loadIntoMemory
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
public SimpleDictionary loadIntoMemory(final DatastoreConnection datastoreConnection) {
final DataContext dataContext = datastoreConnection.getDataContext();
final Column column = getColumn(datastoreConnection);
final Query query = dataContext.query().from(column.getTable()).select(column).toQuery();
if (datastoreConnection.getDatastore().getPerformanceCharacteristics().isQueryOptimizationPreferred()) {
query.getSelectClause().setDistinct(true);
}
final Set<String> values = new HashSet<>();
try (DataSet dataSet = dataContext.executeQuery(query)) {
while (dataSet.next()) {
final Object value = dataSet.getRow().getValue(0);
if (value != null) {
values.add(value.toString());
}
}
}
return new SimpleDictionary(getName(), values);
}
开发者ID:datacleaner,项目名称:DataCleaner,代码行数:23,代码来源:DatastoreDictionary.java
示例4: loadIntoMemory
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
public SimpleSynonymCatalog loadIntoMemory(final DatastoreConnection datastoreConnection) {
final Map<String, String> synonymMap = new HashMap<>();
final Column masterTermColumn = getMasterTermColumn(datastoreConnection);
final Column[] columns = getSynonymColumns(datastoreConnection);
try (DataSet dataSet = datastoreConnection.getDataContext().query().from(masterTermColumn.getTable().getName())
.select(masterTermColumn).select(columns).execute()) {
while (dataSet.next()) {
final Row row = dataSet.getRow();
final String masterTerm = getMasterTerm(row, masterTermColumn);
final String[] synonyms = getSynonyms(row, columns);
for (final String synonym : synonyms) {
synonymMap.put(synonym, masterTerm);
}
}
}
return new SimpleSynonymCatalog(getName(), synonymMap);
}
开发者ID:datacleaner,项目名称:DataCleaner,代码行数:21,代码来源:DatastoreSynonymCatalog.java
示例5: performQuery
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
private Object[] performQuery(final InputRow row, final List<Object> queryInput) {
try {
final Column[] queryConditionColumns = getQueryConditionColumns();
final Object[] parameterValues = new Object[queryConditionColumns.length];
for (int i = 0; i < queryConditionColumns.length; i++) {
parameterValues[i] = queryInput.get(i);
}
try (DataSet dataSet = datastoreConnection.getDataContext().executeQuery(lookupQuery, parameterValues)) {
return handleDataSet(row, dataSet);
}
} catch (final RuntimeException e) {
logger.error("Error occurred while looking up based on conditions: " + queryInput, e);
throw e;
}
}
开发者ID:datacleaner,项目名称:DataCleaner,代码行数:18,代码来源:TableLookupTransformer.java
示例6: DataSetWindow
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
public DataSetWindow(final Query query, final DataContext dataContext, final int pageSize,
final WindowContext windowContext) {
super(windowContext);
_table = new DCTable();
_query = query;
_pageSize = pageSize;
_title = "DataSet: " + _query.toSql();
_tableModelCallable = () -> {
final DataSet dataSet = dataContext.executeQuery(_query);
return new DataSetTableModel(dataSet);
};
_previousPageButton = WidgetFactory.createDefaultButton("Previous page", IconUtils.ACTION_BACK);
_previousPageButton.setEnabled(false);
_nextPageButton = WidgetFactory.createDefaultButton("Next page", IconUtils.ACTION_FORWARD);
_nextPageButton.setHorizontalTextPosition(SwingConstants.LEFT);
_nextPageButton.setEnabled(false);
}
开发者ID:datacleaner,项目名称:DataCleaner,代码行数:18,代码来源:DataSetWindow.java
示例7: getPreviewData
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
private DataSet getPreviewData(final String filename) {
if (!isPreviewDataAvailable()) {
logger.info("Not displaying preview table because isPreviewDataAvailable() returned false");
return null;
}
final D datastore = getPreviewDatastore(filename);
try (DatastoreConnection con = datastore.openConnection()) {
final DataContext dc = con.getDataContext();
final Table table = getPreviewTable(dc);
List<Column> columns = table.getColumns();
if (columns.size() > getPreviewColumns()) {
// include max 10 columns
columns = columns.stream().limit(getPreviewColumns()).collect(Collectors.toList());
}
final Query q = dc.query().from(table).select(columns).toQuery();
q.setMaxRows(7);
return dc.executeQuery(q);
}
}
开发者ID:datacleaner,项目名称:DataCleaner,代码行数:23,代码来源:AbstractFileBasedDatastoreDialog.java
示例8: performAssertions
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
public void performAssertions(final DataSet dataSet, final boolean typeSafe) {
Assert.assertTrue(dataSet.next());
assertEquals("hello, world", dataSet.getRow().getValue(0), typeSafe);
assertEquals(null, dataSet.getRow().getValue(1), typeSafe);
assertEquals(getExampleDate(), dataSet.getRow().getValue(2), typeSafe);
assertEquals(null, dataSet.getRow().getValue(3), typeSafe);
Assert.assertTrue(dataSet.next());
assertEquals(null, dataSet.getRow().getValue(0), typeSafe);
assertEquals(-20, dataSet.getRow().getValue(1), typeSafe);
assertEquals(null, dataSet.getRow().getValue(2), typeSafe);
assertEquals(3.14f, dataSet.getRow().getValue(3), typeSafe);
assertEquals("testObject", dataSet.getRow().getValue(4), typeSafe);
Assert.assertFalse(dataSet.next());
}
开发者ID:datacleaner,项目名称:DataCleaner,代码行数:18,代码来源:OutputWriterScenarioHelper.java
示例9: testFullScenario
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
public void testFullScenario() throws Exception {
final OutputWriterScenarioHelper scenarioHelper = new OutputWriterScenarioHelper();
final String filename = "target/test-output/csv-file1.txt";
final OutputWriter writer = CsvOutputWriterFactory.getWriter(filename, scenarioHelper.getColumns());
scenarioHelper.writeExampleData(writer);
writer.close();
final DataContext dc = DataContextFactory.createCsvDataContext(new File(filename));
final Table table = dc.getDefaultSchema().getTable(0);
final Query q = dc.query().from(table).select(table.getColumns()).toQuery();
final DataSet dataSet = dc.executeQuery(q);
scenarioHelper.performAssertions(dataSet, false);
}
开发者ID:datacleaner,项目名称:DataCleaner,代码行数:17,代码来源:CsvOutputWriterFactoryTest.java
示例10: materializeMainSchemaTable
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
@Override
protected DataSet materializeMainSchemaTable(final Table table, final List<Column> columns, final int maxRows) {
final SelectItem[] tableSelectItems = MetaModelHelper.createSelectItems(table.getColumns().toArray(new Column[0]));
final SelectItem[] selectItems = MetaModelHelper.createSelectItems(columns.toArray(new Column[0]));
final SimpleDataSetHeader header = new SimpleDataSetHeader(tableSelectItems);
final List<Row> rows = new ArrayList<>();
final SimpleDataSetHeader subSelectionHeader = new SimpleDataSetHeader(selectItems);
rows.add(new DefaultRow(header, new Object[] { 1, "hello" }).getSubSelection(subSelectionHeader));
rows.add(new DefaultRow(header, new Object[] { 2, "there" }).getSubSelection(subSelectionHeader));
rows.add(new DefaultRow(header, new Object[] { 3, "big" }).getSubSelection(subSelectionHeader));
rows.add(new DefaultRow(header, new Object[] { 4, "wide" }).getSubSelection(subSelectionHeader));
rows.add(new DefaultRow(header, new Object[] { 5, "world" }).getSubSelection(subSelectionHeader));
return new InMemoryDataSet(rows);
}
开发者ID:datacleaner,项目名称:DataCleaner,代码行数:19,代码来源:SampleDataContext.java
示例11: performQuery
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
private Object[] performQuery(List<Object> queryInput) {
try {
final Column[] queryConditionColumns = getQueryConditionColumns();
final Object[] parameterValues = new Object[queryConditionColumns.length];
for (int i = 0; i < queryConditionColumns.length; i++) {
parameterValues[i] = queryInput.get(i);
}
try (final DataSet dataSet = datastoreConnection.getDataContext()
.executeQuery(lookupQuery, parameterValues)) {
return handleDataSet(dataSet);
}
} catch (RuntimeException e) {
logger.error("Error occurred while looking up based on conditions: " + queryInput, e);
throw e;
}
}
开发者ID:datacleaner,项目名称:AnalyzerBeans,代码行数:19,代码来源:TableLookupTransformer.java
示例12: getValues
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
@Override
public Collection<String> getValues() {
try (final DatastoreConnection con = _datastore.openConnection()) {
final DataContext dataContext = con.getDataContext();
final Query q = dataContext.query().from(_column.getTable()).select(_column).toQuery();
q.selectDistinct();
try (final DataSet dataSet = dataContext.executeQuery(q)) {
final List<String> values = new ArrayList<String>();
while (dataSet.next()) {
final Row row = dataSet.getRow();
Object value = row.getValue(0);
if (value != null) {
value = value.toString();
}
values.add((String) value);
}
return values;
}
}
}
开发者ID:datacleaner,项目名称:AnalyzerBeans,代码行数:24,代码来源:DatastoreReferenceValues.java
示例13: materializeMainSchemaTable
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
@Override
protected DataSet materializeMainSchemaTable(Table table, Column[] columns, int maxRows) {
DataInputStream inputStream = createInputStream();
// skip through the metadata section
try {
readMetadataSection(inputStream);
} catch (RuntimeException e) {
FileHelper.safeClose(inputStream);
throw e;
}
DataSet dataSet = new KettleDataSet(columns, inputStream, rowMeta);
if (maxRows >= 0) {
dataSet = new MaxRowsDataSet(dataSet, maxRows);
}
return dataSet;
}
开发者ID:datacleaner,项目名称:pdi-datacleaner,代码行数:19,代码来源:KettleDataContext.java
示例14: materializeMainSchemaTable
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
@Override
protected DataSet materializeMainSchemaTable(Table table, List<Column> columns, int firstRow, int maxRows) {
// the connector represents a handle to the the couchdb "database".
final String databaseName = table.getName();
final CouchDbConnector connector = _couchDbInstance.createConnector(databaseName, false);
ViewQuery query = new ViewQuery().allDocs().includeDocs(true);
if (maxRows > 0) {
query = query.limit(maxRows);
}
if (firstRow > 1) {
final int skip = firstRow - 1;
query = query.skip(skip);
}
final StreamingViewResult streamingView = connector.queryForStreamingView(query);
final List<SelectItem> selectItems = columns.stream().map(SelectItem::new).collect(Collectors.toList());
return new CouchDbDataSet(selectItems, streamingView);
}
开发者ID:apache,项目名称:metamodel,代码行数:22,代码来源:CouchDbDataContext.java
示例15: executeQuery
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
@Override
public DataSet executeQuery(Table table, List<Column> columns, int maxRows) {
final Workbook wb = ExcelUtils.readWorkbook(_resource);
final Sheet sheet = wb.getSheet(table.getName());
if (sheet == null || sheet.getPhysicalNumberOfRows() == 0) {
return new EmptyDataSet(columns.stream().map(SelectItem::new).collect(Collectors.toList()));
}
DataSet dataSet = ExcelUtils.getDataSet(wb, sheet, table, _configuration);
if (maxRows > 0) {
dataSet = new MaxRowsDataSet(dataSet, maxRows);
}
return dataSet;
}
开发者ID:apache,项目名称:metamodel,代码行数:17,代码来源:DefaultSpreadsheetReaderDelegate.java
示例16: testGroupByQuery
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
@Test
public void testGroupByQuery() throws Exception {
Table table = dataContext.getDefaultSchema().getTableByName(peopleIndexType);
Query q = new Query();
q.from(table);
q.groupBy(table.getColumnByName("gender"));
q.select(new SelectItem(table.getColumnByName("gender")),
new SelectItem(FunctionType.MAX, table.getColumnByName("age")),
new SelectItem(FunctionType.MIN, table.getColumnByName("age")), new SelectItem(FunctionType.COUNT, "*",
"total"), new SelectItem(FunctionType.MIN, table.getColumnByName("id")).setAlias("firstId"));
q.orderBy("gender");
DataSet data = dataContext.executeQuery(q);
assertEquals(
"[peopletype.gender, MAX(peopletype.age), MIN(peopletype.age), COUNT(*) AS total, MIN(peopletype.id) AS firstId]",
Arrays.toString(data.getSelectItems().toArray()));
assertTrue(data.next());
assertEquals("Row[values=[female, 20, 17, 5, 5]]", data.getRow().toString());
assertTrue(data.next());
assertEquals("Row[values=[male, 19, 17, 4, 1]]", data.getRow().toString());
assertFalse(data.next());
}
开发者ID:apache,项目名称:metamodel,代码行数:24,代码来源:ElasticSearchDataContextTest.java
示例17: testDoubleQuoteEscape
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
@Test
public void testDoubleQuoteEscape() throws Exception {
CsvConfiguration configuration = new CsvConfiguration(1, "UTF-8", ',', '"', '"');
CsvDataContext dc = new CsvDataContext(new File("src/test/resources/csv_doublequoteescape.csv"), configuration);
DataSet dataSet = dc.query().from("csv_doublequoteescape.csv").select("age", "name").execute();
assertTrue(dataSet.next());
assertEquals("Row[values=[18, mi\"ke]]", dataSet.getRow().toString());
assertEquals("mi\"ke", dataSet.getRow().getValue(dc.getColumnByQualifiedLabel("name")));
assertTrue(dataSet.next());
assertEquals("Row[values=[19, mic\"hael]]", dataSet.getRow().toString());
assertTrue(dataSet.next());
assertEquals("Row[values=[18, pet\"er]]", dataSet.getRow().toString());
assertTrue(dataSet.next());
assertEquals("Row[values=[18, barbar\"a, \"\"barb]]", dataSet.getRow().toString());
dataSet.close();
}
开发者ID:apache,项目名称:metamodel,代码行数:22,代码来源:DoubleQuoteEscapeTest.java
示例18: testExecuteQueryBeforeLoadingSchema
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
/**
* Tests that you can execute a query on a ExcelDataContext even though the
* schema has not yet been (explicitly) loaded.
*/
public void testExecuteQueryBeforeLoadingSchema() throws Exception {
// first use one DataContext to retreive the schema/table/column objects
ExcelDataContext dc1 = new ExcelDataContext(copyOf("src/test/resources/Spreadsheet2007.xlsx"));
Schema schema = dc1.getDefaultSchema();
Table table = schema.getTable(0);
Column column = table.getColumn(0);
// query another DataContext using the schemas of the one above
ExcelDataContext dc2 = new ExcelDataContext(copyOf("src/test/resources/Spreadsheet2007.xlsx"));
DataSet ds = dc2.executeQuery(new Query().from(table).select(column));
// previously we would crash at this point!
assertNotNull(ds);
ds.close();
}
开发者ID:apache,项目名称:metamodel,代码行数:21,代码来源:ExcelDataContextTest.java
示例19: testApproximatedCountSmallFile
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
public void testApproximatedCountSmallFile() throws Exception {
DataContext dc = new CsvDataContext(new File("src/test/resources/csv_people.csv"));
Table table = dc.getDefaultSchema().getTables().get(0);
Query q = dc.query().from(table).selectCount().toQuery();
SelectItem selectItem = q.getSelectClause().getItem(0);
selectItem.setFunctionApproximationAllowed(true);
DataSet ds = dc.executeQuery(q);
assertTrue(ds.next());
Object[] values = ds.getRow().getValues();
assertEquals(1, values.length);
assertEquals(9, ((Long) ds.getRow().getValue(selectItem)).intValue());
assertEquals(9, ((Long) values[0]).intValue());
assertFalse(ds.next());
}
开发者ID:apache,项目名称:metamodel,代码行数:17,代码来源:CsvDataContextTest.java
示例20: testQuerySameScalarFunctionOnSameColumnButDifferentParamsInBothSelectAndWhere
import org.apache.metamodel.data.DataSet; //导入依赖的package包/类
public void testQuerySameScalarFunctionOnSameColumnButDifferentParamsInBothSelectAndWhere() throws Exception {
final DataContext dc = getDataContext();
final Query query = dc.parseQuery(
"SELECT SUBSTRING(name, 1, 3) FROM contributor WHERE SUBSTRING(name, 4, 3) = 'per' ORDER BY contributor_id");
// assert on the parsed select items just to ensure that nothing gets mangled in the parsing
assertSame(FunctionType.SUBSTRING, query.getSelectClause().getItem(0).getScalarFunction());
assertEquals(" 1", query.getSelectClause().getItem(0).getFunctionParameters()[0]);
assertEquals(" 3", query.getSelectClause().getItem(0).getFunctionParameters()[1]);
assertSame(FunctionType.SUBSTRING, query.getWhereClause().getItem(0).getSelectItem().getScalarFunction());
assertEquals(" 4", query.getWhereClause().getItem(0).getSelectItem().getFunctionParameters()[0]);
assertEquals(" 3", query.getWhereClause().getItem(0).getSelectItem().getFunctionParameters()[1]);
try (DataSet ds = dc.executeQuery(query)) {
assertTrue(ds.next());
// name is "kasper"
final Object value1 = ds.getRow().getValue(0);
assertEquals("kas", value1.toString());
assertTrue(ds.next());
// name is "jesper"
final Object value2 = ds.getRow().getValue(0);
assertEquals("jes", value2.toString());
assertFalse(ds.next());
}
}
开发者ID:apache,项目名称:metamodel,代码行数:26,代码来源:QueryPostprocessDataContextTest.java
注:本文中的org.apache.metamodel.data.DataSet类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论