Skip to content

Commit

Permalink
Merge pull request #280 from juneng603/feature-fix-misspelled-words
Browse files Browse the repository at this point in the history
Feature fix misspelled words
  • Loading branch information
hjafarpour authored Sep 5, 2017
2 parents 9c52487 + 6b896d7 commit 1e5496b
Show file tree
Hide file tree
Showing 6 changed files with 7 additions and 7 deletions.
2 changes: 1 addition & 1 deletion docs/quickstart/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -143,7 +143,7 @@ Before proceeding, please check:
GENDER | VARCHAR(STRING)
```

3. Use `SELECT` to view query results as they come in. To stop viewing the query results, press `<ctrl-c>`. This stops printing to the console but it does not terminate the actual query. The query continues to run in the underyling KSQL application.
3. Use `SELECT` to view query results as they come in. To stop viewing the query results, press `<ctrl-c>`. This stops printing to the console but it does not terminate the actual query. The query continues to run in the underlying KSQL application.

```bash
ksql> SELECT * FROM pageviews_female;
Expand Down
4 changes: 2 additions & 2 deletions ksql-core/src/main/java/io/confluent/ksql/QueryEngine.java
Original file line number Diff line number Diff line change
Expand Up @@ -236,7 +236,7 @@ public void buildQueryPhysicalPlan(final List<QueryMetadata> physicalPlans,
}
String serviceId = ksqlEngine.getKsqlConfig()
.get(KsqlConfig.KSQL_SERVICE_ID_CONFIG).toString();
String persistance_query_prefix = ksqlEngine.getKsqlConfig()
String persistence_query_prefix = ksqlEngine.getKsqlConfig()
.get(KsqlConfig.KSQL_PERSISTENT_QUERY_NAME_PREFIX_CONFIG).toString();
String transient_query_prefix = ksqlEngine.getKsqlConfig()
.get(KsqlConfig.KSQL_TRANSIENT_QUERY_NAME_PREFIX_CONFIG).toString();
Expand Down Expand Up @@ -267,7 +267,7 @@ public void buildQueryPhysicalPlan(final List<QueryMetadata> physicalPlans,
} else if (outputNode instanceof KsqlStructuredDataOutputNode) {
long queryId = getNextQueryId();

String applicationId = serviceId + persistance_query_prefix +
String applicationId = serviceId + persistence_query_prefix +
queryId;
if (addUniqueTimeSuffix) {
applicationId = addTimeSuffix(applicationId);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -111,7 +111,7 @@ public AbstractCreateStreamCommand(final AbstractStreamCreateStatement statement
}

private void checkTopicNameNotNull(Map<String, Expression> properties) {
// TODO: move the check to grammer
// TODO: move the check to grammar
KsqlPreconditions.checkNotNull(
properties.get(DdlConfig.TOPIC_NAME_PROPERTY),
"Topic name should be set in WITH clause.");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ public boolean equals(Object o) {

if (columns.size() != that.columns.size()) return false;

// For now string matching is used to compare the rows as double comparision will cause issues
// For now string matching is used to compare the rows as double comparison will cause issues
return this.toString().equals(that.toString());
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ public class KsqlConfig extends AbstractConfig {
KSQL_SERVICE_ID_IMPORTANCE = ConfigDef.Importance.MEDIUM;
public static final String
KSQL_SERVICE_ID_DOC =
"Indicates the ID of the ksql service. It will be used as prefix for all KSQL queires in "
"Indicates the ID of the ksql service. It will be used as prefix for all KSQL queries in "
+ "this service.";

public static final String
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@
public class StringUtil {

public static String cleanQuotes(final String stringWithQuotes) {
// TODO: move check to grammer
// TODO: move check to grammar
if (stringWithQuotes.startsWith("'") && stringWithQuotes.endsWith("'")) {
return stringWithQuotes.substring(1, stringWithQuotes.length() - 1);
} else {
Expand Down

0 comments on commit 1e5496b

Please sign in to comment.