MCPcopy Create free account

hub / github.com/cata-network/cata_database / functions

Functions323 in github.com/cata-network/cata_database

MethodcreateNewTable
(String tableName, List<String> partitionColumns, StorageStrategy storageStrategy)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSchemaFactory.java:86
MethodcurrentChar
{@inheritDoc}
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingContext.java:64
MethodcurrentColumn
{@inheritDoc}
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingContext.java:72
MethodcurrentLine
{@inheritDoc}
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingContext.java:56
MethodcurrentParsedContent
{@inheritDoc}
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingContext.java:104
Methoddeserialize
(JsonParser jp, DeserializationContext ctxt)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSubScan.java:148
Methoddump
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriterRecordBatch.java:242
MethodendEmptyField
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/HeaderBuilder.java:87
MethodendEmptyField
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/RepeatedVarCharOutput.java:265
MethodendEmptyField
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/FieldVarCharOutput.java:203
MethodendRecord
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSJSONRecordWriter.java:70
MethodextractedFieldIndexes
{@inheritDoc}
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingContext.java:88
Methodfinish
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSJSONRecordWriter.java:95
MethodfinishBatch
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/HeaderBuilder.java:245
MethodfinishBatch
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/RepeatedVarCharOutput.java:345
MethodfinishBatch
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/FieldVarCharOutput.java:222
MethodfinishBatch
Finish the processing of a batch, indicates to the output interface to wrap up the batch
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:487
MethodfinishRecord
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/HeaderBuilder.java:197
MethodfinishRecord
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/RepeatedVarCharOutput.java:295
MethodfinishRecord
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/FieldVarCharOutput.java:208
Methodget
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSHelper.java:50
MethodgetBatch
(ExecutorFragmentContext context, IPFSSubScan subScan, List<RecordBatch> children)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSScanBatchCreator.java:23
MethodgetBatch
(ExecutorFragmentContext context, IPFSWriter config, List<RecordBatch> children)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriterBatchCreator.java:14
MethodgetColumns
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:267
MethodgetConfig
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePlugin.java:83
MethodgetDefaultColumnsToRead
Returns list of default columns to read to replace empty list of columns. For text files without headers returns "columns[0]". Text files with headers
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/IPFSTextRecordReader.java:77
MethodgetDigest
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:385
MethodgetEmptyValue
Returns the String representation of an empty value (defaults to null) <p>When reading, if the parser does not read any character from the input, and
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:184
MethodgetExtensions
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextFormatConfig.java:24
MethodgetFieldDelimiterAsString
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextFormatConfig.java:53
MethodgetFormats
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePluginConfig.java:124
MethodgetIPFSClient
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePlugin.java:74
MethodgetIPFSContext
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSubScan.java:67
MethodgetIPFSScanSpec
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:277
MethodgetIPFSStoragePluginConfig
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSubScan.java:72
MethodgetIPFSStoragePluginConfig
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSScanSpec.java:187
MethodgetIPNSDataHash
(Multihash peerId)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSHelper.java:216
MethodgetLineCount
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextInput.java:356
MethodgetMaxParallelizationWidth
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:290
MethodgetNewWithChild
(PhysicalOperator child)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriter.java:46
MethodgetNewWithChildren
(List<PhysicalOperator> children)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSubScan.java:114
MethodgetNewWithChildren
(List<PhysicalOperator> children)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:375
MethodgetOperatorAffinity
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:282
MethodgetOperatorType
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSubScan.java:104
MethodgetOperatorType
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriter.java:41
MethodgetOptimizerRules
(OptimizerRulesContext optimizerContext, PlannerPhase phase)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePlugin.java:64
MethodgetOutput
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:94
MethodgetPartitionColumns
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSchemaFactory.java:100
MethodgetPeerDrillHostname
(Multihash peerId)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSHelper.java:204
MethodgetPhysicalScan
(String userName, JSONOptions selection)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePlugin.java:48
MethodgetPos
{@inheritDoc}
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/SeekableByteArrayInputStream.java:53
MethodgetPrefix
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSScanSpec.java:172
MethodgetRecordCount
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/HeaderBuilder.java:239
MethodgetRecordCount
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/RepeatedVarCharOutput.java:285
MethodgetRecordCount
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/FieldVarCharOutput.java:225
MethodgetScanStats
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:353
MethodgetSpecificScan
(int minorFragmentId)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:337
MethodgetStorageConfig
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriter.java:55
MethodgetSubSchema
(String name)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSchemaFactory.java:76
MethodgetSubSchemaNames
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSchemaFactory.java:81
MethodgetTable
(String tableName)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSchemaFactory.java:63
MethodgetTableNames
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSchemaFactory.java:58
MethodgetTargetHash
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSubScan.java:127
MethodgetTextOutput
This method is a helper method added for DRILL-951 IPFSTextRecordReader to call this method to get field names out @return array of field data strings
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/RepeatedVarCharOutput.java:325
MethodgetTotalBytes
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:415
MethodgetTypeName
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSchemaFactory.java:53
MethodgetWriter
(PhysicalOperator child)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSchemaFactory.java:95
MethodhashCode
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePluginConfig.java:128
MethodhashCode
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSPeer.java:76
MethodhashCode
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextFormatConfig.java:68
Methodheaders
{@inheritDoc}
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingContext.java:80
MethodinnerNext
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriterRecordBatch.java:67
MethodisDelimiter
Identifies whether or not a given character represents a field delimiter @param ch the character to be verified @return true if the given character is
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:173
MethodisDrillReady
(Multihash peerId)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSHelper.java:208
MethodisExecutable
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSubScan.java:109
MethodisMutable
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSchemaFactory.java:108
MethodisQuote
Identifies whether or not a given character is used for escaping values where the field delimiter is part of the value @param ch the character to be v
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:123
MethodisQuoteEscape
Identifies whether or not a given character is used for escaping quotes inside an already quoted value. @param ch the character to be verified @return
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:148
MethodisStopped
{@inheritDoc}
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingContext.java:48
MethodkillIncoming
(boolean sendUpstream)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriterRecordBatch.java:57
Methodload
(Multihash key)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSContext.java:29
Methodnext
Generates the next record batch @return number of records in the batch
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/IPFSTextRecordReader.java:179
MethodonMatch
(RelOptRuleCall call)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSAggWriterPrule.java:20
MethodreadFully
{@inheritDoc}
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/SeekableByteArrayInputStream.java:93
MethodregisterSchemas
(SchemaConfig schemaConfig, SchemaPlus parent)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePlugin.java:78
MethodregisterSchemas
(SchemaConfig schemaConfig, SchemaPlus parent)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSchemaFactory.java:34
MethodrowHasData
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/HeaderBuilder.java:248
MethodrowHasData
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/RepeatedVarCharOutput.java:290
MethodrowHasData
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/FieldVarCharOutput.java:230
MethodseekToNewSource
{@inheritDoc}
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/SeekableByteArrayInputStream.java:61
Methodserialize
(List<Multihash> value, JsonGenerator jgen, SerializerProvider provider)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSubScan.java:135
MethodsetComment
(byte comment)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:257
MethodsetDelimiter
Defines the field delimiter character. Defaults to ',' @param delimiter the field delimiter character
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:164
MethodsetEmptyValue
Sets the String representation of an empty value (defaults to null) <p>When reading, if the parser does not read any character from the input, and th
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:195
MethodsetFieldDelimiter
(char delimiter)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextFormatConfig.java:58
MethodsetIgnoreLeadingWhitespaces
(boolean ignoreLeadingWhitespaces)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:273
MethodsetIgnoreTrailingWhitespaces
(boolean ignoreTrailingWhitespaces)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:281
MethodsetMaxCharsPerColumn
(long maxCharsPerColumn)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:253
MethodsetNormalizedNewLine
(byte normalizedNewLine)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:265
MethodsetNumberOfRecordsToRead
Defines the number of valid records to be parsed before the process is stopped. A negative value indicates there's no limit (defaults to -1). @param n
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:245
← previousnext →201–300 of 323, ranked by callers